<?php

if (!defined('IN_SEXMALL'))
{
	die('Hacking attempt');
}

define('SMTP_STATUS_NOT_CONNECTED', 1, true);
define('SMTP_STATUS_CONNECTED',     2, true);

class smtp
{
	var $connection;
	var $recipients;
	var $headers;
	var $timeout;
	var $errors;
	var $status;
	var $body;
	var $from;
	var $host;
	var $port;
	var $helo;
	var $auth;
	var $user;
	var $pass;

	/**
	 *  参数为一个数组
	 *  host        SMTP 服务器的主机       默认：localhost
	 *  port        SMTP 服务器的端口       默认：25
	 *  helo        发送HELO命令的名称      默认：localhost
	 *  user        SMTP 服务器的用户名     默认：空值
	 *  pass        SMTP 服务器的登陆密码   默认：空值
	 *  timeout     连接超时的时间          默认：5
	 *  @return  bool
	 */
	function smtp($params = array())
	{
		if (!defined('CRLF'))
		{
			define('CRLF', "\r\n", true);
		}

		$this->timeout  = 10;
		$this->status   = SMTP_STATUS_NOT_CONNECTED;
		$this->host     = 'localhost';
		$this->port     = 25;
		$this->auth     = false;
		$this->user     = '';
		$this->pass     = '';
		$this->errors   = array();

		foreach ($params AS $key => $value)
		{
			$this->$key = $value;
		}

		$this->helo     = $this->host;

		//  如果没有设置用户名则不验证
		$this->auth = ('' == $this->user) ? false : true;
	}

	function connect($params = array())
	{
		if (!isset($this->status))
		{
			$obj = new smtp($params);

			if ($obj->connect())
			{
				$obj->status = SMTP_STATUS_CONNECTED;
			}

			return $obj;
		}
		else
		{
			if (!empty($GLOBALS['_CFG']['smtp_ssl']))
			{
				$this->host = "ssl://" . $this->host;
			}
			$this->connection = @fsockopen($this->host, $this->port, $errno, $errstr, $this->timeout);

			if ($this->connection === false)
			{
				$this->errors[] = 'Access is denied.';

				return false;
			}

			@socket_set_timeout($this->connection, 0, 250000);

			$greeting = $this->get_data();

			if (is_resource($this->connection))
			{
				$this->status = 2;

				return $this->auth ? $this->ehlo() : $this->helo();
			}
			else
			{
				log_write($errstr, __FILE__, __LINE__);
				$this->errors[] = 'Failed to connect to server: ' . $errstr;

				return false;
			}
		}
	}

	/**
	 * 参数为数组
	 * recipients      接收人的数组
	 * from            发件人的地址，也将作为回复地址
	 * headers         头部信息的数组
	 * body            邮件的主体
	 */

	function send($params = array())
	{
		foreach ($params AS $key => $value)
		{
			$this->$key = $value;
		}

		if ($this->is_connected())
		{
			//  服务器是否需要验证
			if ($this->auth)
			{
				if (!$this->auth())
				{
					return false;
				}
			}

			$this->mail($this->from);

			if (is_array($this->recipients))
			{
				foreach ($this->recipients AS $value)
				{
					$this->rcpt($value);
				}
			}
			else
			{
				$this->rcpt($this->recipients);
			}

			if (!$this->data())
			{
				return false;
			}

			$headers = str_replace(CRLF . '.', CRLF . '..', trim(implode(CRLF, $this->headers)));
			$body    = str_replace(CRLF . '.', CRLF . '..', $this->body);
			$body    = substr($body, 0, 1) == '.' ? '.' . $body : $body;

			$this->send_data($headers);
			$this->send_data('');
			$this->send_data($body);
			$this->send_data('.');

			return (substr($this->get_data(), 0, 3) === '250');
		}
		else
		{
			$this->errors[] = 'Not connected!';

			return false;
		}
	}

	function helo()
	{
		if (is_resource($this->connection)
		AND $this->send_data('HELO ' . $this->helo)
		AND substr($error = $this->get_data(), 0, 3) === '250' )
		{
			return true;
		}
		else
		{
			$this->errors[] = 'HELO command failed, output: ' . trim(substr($error, 3));

			return false;
		}
	}

	function ehlo()
	{
		if (is_resource($this->connection)
		AND $this->send_data('EHLO ' . $this->helo)
		AND substr($error = $this->get_data(), 0, 3) === '250' )
		{
			return true;
		}
		else
		{
			$this->errors[] = 'EHLO command failed, output: ' . trim(substr($error, 3));

			return false;
		}
	}

	function auth()
	{
		if (is_resource($this->connection)
		AND $this->send_data('AUTH LOGIN')
		AND substr($error = $this->get_data(), 0, 3) === '334'
		AND $this->send_data(base64_encode($this->user))            // Send username
		AND substr($error = $this->get_data(),0,3) === '334'
		AND $this->send_data(base64_encode($this->pass))            // Send password
		AND substr($error = $this->get_data(),0,3) === '235' )
		{
			return true;
		}
		else
		{
			$this->errors[] = 'AUTH command failed: ' . trim(substr($error, 3));

			return false;
		}
	}

	function mail($from)
	{
		if ($this->is_connected()
		AND $this->send_data('MAIL FROM:<' . $from . '>')
		AND substr($this->get_data(), 0, 2) === '250' )
		{
			return true;
		}
		else
		{
			return false;
		}
	}

	function rcpt($to)
	{
		if ($this->is_connected()
		AND $this->send_data('RCPT TO:<' . $to . '>')
		AND substr($error = $this->get_data(), 0, 2) === '25')
		{
			return true;
		}
		else
		{
			$this->errors[] = trim(substr($error, 3));

			return false;
		}
	}

	function data()
	{
		if ($this->is_connected()
		AND $this->send_data('DATA')
		AND substr($error = $this->get_data(), 0, 3) === '354' )
		{
			return true;
		}
		else
		{
			$this->errors[] = trim(substr($error, 3));

			return false;
		}
	}

	function is_connected()
	{
		return (is_resource($this->connection) AND ($this->status === SMTP_STATUS_CONNECTED));
	}

	function send_data($data)
	{
		if (is_resource($this->connection))
		{
			return fwrite($this->connection, $data . CRLF, strlen($data) + 2);
		}
		else
		{
			return false;
		}
	}

	function get_data()
	{
		$return = '';
		$line   = '';

		if (is_resource($this->connection))
		{
			while (strpos($return, CRLF) === false OR $line{3} !== ' ')
			{
				$line    = fgets($this->connection, 512);
				$return .= $line;
			}

			return trim($return);
		}
		else
		{
			return '';
		}
	}

	/**
	 * 获得最后一个错误信息
	 *
	 * @access  public
	 * @return  string
	 */
	function error_msg()
	{
		if (!empty($this->errors))
		{
			$len = count($this->errors) - 1;
			return $this->errors[$len];
		}
		else
		{
			return '';
		}
	}
}

?>